package com.bbcare.cp.plat.store.ibatis.msg;

import java.util.List;
import java.util.Map;

import com.bbcare.cp.plat.entity.msg.PtSynchBusiMsg;

public interface IPtSynchBusiMsgDAO {
    // 插入消息
    int insertPtSynchBusiMsg(PtSynchBusiMsg msg) throws Exception;

    // 查询待发送消息列表（多线程）
    List<PtSynchBusiMsg> listMsgInfo(Map<String, Object> arg) throws Exception;

    // 查询待发送消息列表（单线程）
    List<PtSynchBusiMsg> listMsgInfoForOneThread(Map<String, Object> arg) throws Exception;

    // 单条更新消息记录 发送状态、发送结果 发送时间等
    int updateMsgInfo(Map<String, Object> arg) throws Exception;

    // 批量更新消息记录
    int batchUpdateMsgInfo(Map<String, Object> arg) throws Exception;

    // 批量插入历史
    int batchInsertMsgHis(Map<String, Object> arg) throws Exception;

    // 批量删除
    int batchDeleteMsg(Map<String, Object> arg) throws Exception;
}
